package org.lql.chaos.rocketmq.callback;

import lombok.extern.slf4j.Slf4j;
import org.apache.rocketmq.client.producer.SendResult;
import org.springframework.stereotype.Component;

/**
 * @author: liangqinglong
 * @date: 2025-08-16 21:11
 * @description:
 **/
@Slf4j
@Component
public class OrderSendCallback extends AbstractSendCallback {

	@Override
	protected void doOnSuccess(SendResult sendResult) {
		// 订单业务特定的成功处理逻辑
		log.info("订单业务处理成功，消息ID：{}", sendResult.getMsgId());
	}

	@Override
	protected void doOnException(Throwable throwable) {
		// 订单业务特定的异常处理逻辑
		log.error("订单业务处理异常", throwable);
	}
}
